//package com.guchenbo.spark.sql
//
//import com.guchenbo.spark.sql.CsvReader.path
//import org.apache.spark.sql.SparkSession
//
//object Test {
//  def main(args: Array[String]): Unit = {
//    val spark = SparkSession.builder().master("local").appName("CreateTableDemo").getOrCreate()
//
//    val sr = spark.read
//      .option("sep", ";")
//      .option("encoding", "UTF-8")
//      .option("header", "true")
//      .option("escape", "\"")
//      .option("mode", dataMassCheck)
//    //      .option("columnNameOfCorruptRecord", "columnNameOfCorruptRecord")
//    //      .option("nanValue","NaN")
//    //          .option("inferSchema", value = true)
//
//    sr.schema(schema)
//
//    val df = sr.csv(path("people.csv"))
//  }
//}
